package com.tongzhan.monitor;

import org.apache.rocketmq.spring.annotation.RocketMQMessageListener;
import org.apache.rocketmq.spring.core.RocketMQListener;
import org.springframework.web.bind.annotation.RestController;

@RestController
@RocketMQMessageListener(consumerGroup = "tongzhan-massge-center",topic = "sendMessage")
public class RocketMQMonitor implements RocketMQListener<String> {
    @Override
    public void onMessage(String s) {
        System.out.println(s);
    }
}
